package io.mft.commons.config.mq;

import java.io.File;
import java.nio.charset.Charset;
import java.util.ArrayList;
import java.util.List;

import cn.hutool.json.JSONObject;
import cn.hutool.json.JSONUtil;

/**
 * json数据源配置解析
 * 
 * @说明：TODO
 * @类型名称：MqConfigJsonConfigParser
 * @创建者: 胡常建
 * @创建时间: 2021年2月1日 下午3:17:31
 * @修改者: 胡常建
 * @修改时间: 2021年2月1日 下午3:17:31
 */
public class MqConfigJsonConfigParser {
	public static List<MqConfig> parse() {
		List<MqConfig> mqConfigs=new ArrayList<MqConfig>();
		String path = MqConfigJsonConfigParser.class.getClassLoader().getResource(".").getPath() + File.separator+"config"+File.separator
				+"mq";
		
		File dir = new File(path);
		String[] sysDirs=dir.list();
		for (String sysDir : sysDirs) {
			String config=path+File.separator+sysDir+File.separator+ "mq-config.json";
			File f = new File(config);
			if (f.exists()&&f.isFile()) {
				Charset charset = Charset.forName("UTF-8");
				JSONObject jsonObject = JSONUtil.readJSONObject(f, charset);
				MqConfig dsConfig=jsonObject.toBean(MqConfig.class);
				mqConfigs.add(dsConfig);
			}
		}
		return mqConfigs;
	}
}
